package com.apex.flink.source;

import com.apex.flink.FlinkEnvironment;
import com.apex.flink.stream.FlinkStreamSource;
import com.typesafe.config.Config;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.types.Row;

public class Fake implements FlinkStreamSource<Row> {
    private Config config;
    @Override
    public void prepare(FlinkEnvironment plugin) {

    }

    @Override
    public Config getConfig() {
        return config;
    }

    @Override
    public void setConfig(Config config) {
        this.config = config;
    }

    @Override
    public DataStream<Row> getData(FlinkEnvironment env) {
        return null;
    }
}
